package com.alib.springcloud.service;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;

/**
 * Stream - input - 订阅者 ，监听 发布者的 消息，它发布一条，我监听一条。
 * 若同组，则竞争 发布者消息
 * */

@EnableBinding(Sink.class) // 1、开启 订阅通道
public class IMessageConsumer {

    @Value("${server.port}")
    private String serverPort;

    @StreamListener(Sink.INPUT) //2、绑定通道监听
    public void input(Message<String> message){ //这个入参，得看发布者，用的什么参数发送
        System.out.println( "消费者"+serverPort +"------->接收到的消息：" + message.getPayload()  );
    }


}
